#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>


#define FTOK_PATH	"/dev/zero"
#define FTOK_PROJID	22


typedef struct s_msgbuf
{
	long	mtype;
	char	mtext[512];

}t_msbuf;

int main(int argc,char **argv)
{
	key_t	key;
	int	msgid;
	t_msbuf	msgbuf;
	int	msgtype;
	int	i;

	if( (key=ftok(FTOK_PATH,FTOK_PROJID)) < 0 )
	{
		printf("ftok() get IPC token failure: %S\n",strerror(errno));
		return -1;
	}

	msgid = msgget(key,IPC_CREAT|0666);
	if(msgid<0)
	{
		printf("msgget() create MQ ID failure: %s\n",strerror(errno));
		return -2;
	}
	msgtype = (int)key;
	printf("key[%d] msgid[%d] msgtype[%d]\n",(int)key,msgid,msgtype);

	for(i=0;i<4;i++)
	{
		msgbuf.mtype = msgtype;
		strcpy(msgbuf.mtext,"Ping");


		if( msgsnd(msgid,&msgbuf,sizeof(msgbuf.mtext),IPC_NOWAIT) < 0 )
		{
			printf("msgsnd() send message failure: %s\n",strerror(errno));
			break;
		
		}

		printf("Send message: %s\n",msgbuf.mtext);

		sleep(1);
	}

	msgctl(msgid,IPC_RMID,NULL);
	return 0;
}
